package xyz.xtt.exchange.service;

import xyz.xtt.exchange.constants.RocketMessageDelayLevelEnum;

/**
 * @author huqibo 发送延时消息
 */
public interface IRocketMqService {
	/**
	 * 发送延时消息
	 * 
	 * @param topic
	 * @param message
	 * @param delayLevel
	 */
	public void sendDelayedMessage(String topic, String message, RocketMessageDelayLevelEnum delayLevel);
}
